package com.gallop.mq.core;

import com.gallop.mq.core.dispatcher.DispatchContext;

import java.util.Collection;

public interface MQMessageDispatcher {

    void addRoutes(Collection<MQMessageListenerContainer> containers);

    void dispatch(DispatchContext dispatchContext);

    Collection<MQMessageListenerContainer> getAllContainers();

    MQReliableRegistry getReliableRegistry();

    void setReliableRegistry(MQReliableRegistry reliableRegistry);
}
